// 微信小程序实现sse,通过wx自己的方式实现 -- 该接口有一个明显的问题，同时只能触发一次
export const SSE_WX = ({
  url,
  pData,
  success,
  error,
  finish
}) => {

  console.log('start testAI sse')

  // lastArrayBuffer = null // 重置半个流数据
  // 接口赋值
  let requestTask = null
  let dataContent = ''
  try {

    const requestTask = wx.request({
      url: `https://wss.lke.cloud.tencent.com/v1/qbot/chat/sse`,
      header: {
        "Content-Type": "application/json",
      },
      data: {
        "session_id": "a29bae68-cb1c-489d-8097-6be78f136a10",
        "bot_app_key": "wWyoNsgkeVwpwJnaRxCItIwsYPqzEJBHGOigsFUQSFDkfOAQivXcZCISbObgGEySRTeWSHVUgLHMIriOKAleAREAohbnlXGeLGlFPyViecLyPunELQpBrrfLmdUZxmWJ",
        "visitor_biz_id": "a29bae68-cb1c-489d-8097-6be78f136acf",
        "content": "从'药品销售'中查询一下'品名'为'二硫化硒洗剂'的药品在'销售时间'为2023年11月的销售明细，结果信息展示字段：销售时间、商品ID、品名、规格、厂商、单位、税率、零售价、销售数量、销售价、销售金额、部门编码、部门名称、部门地址、销售总单号、销售细单号、批号、有效期、批准文号、销售人员编码、销售人员名称",
        "incremental": true,
        "streaming_throttle": 10,
        "visitor_labels": [],
        "custom_variables": {}
      },
      method: "POST",
      timeout: '120000',
      enableChunked: true, // 启用分块接收
      // 执行完成
      complete(res) {
        console.log('执行完成')
        console.log(res)
        //LegacyMessage.delete(uid)
        //lastArrayBuffer.delete(uid)
        // 触发完成回调
        if (finish && typeof finish === 'function') {
          console.log('执行完成 finish')
          finish(res)
        }
      }
    });
    // 监听服务端返回的数据
    requestTask.onChunkReceived((res) => {
      // Uint8Array转为text格式
      const arrayBuffer = res.data;
      let decoder = new TextDecoder("utf-8"); // 本地开发者工具使用
      let texts = decoder.decode(arrayBuffer); // 本地开发者工具使用
      // let texts = arrayBufferToString(arrayBuffer); // 真机使用

      // 看一下 打印出来的结果
      // console.log(text);
      texts = texts.split("\n"); // 将接收到的字符串按换行符分割成数组
      // 处理每个以 'data: ' 开头的字符串
      texts.forEach((text) => {
        if (text.trim().length > 0) {
          console.log("原始文本:", text);
          try {
            const jsonString = text.replace(/^data:\s*/, ""); // 去掉前缀
            // 检查 jsonString 是否有效 JSON
            if (
              jsonString.trim().startsWith("{") &&
              jsonString.trim().endsWith("}")
            ) {
              const jsonData = JSON.parse(jsonString);
              console.log('jsonData:', jsonData);
              listener(jsonData);
            } else {
              console.error("无效的 JSON 格式:", jsonString);
            }
          } catch (error) {
            console.error("解析 JSON 时出错:", error);
            console.log("原始文本:", text); // 输出原始文本以便调试
          }
        }
      });
      // listener(text)
    });

    // requestTask.onComplete(() => {
    //   console.log("请求完成");
    //   // 这里可以处理请求完成后的逻辑
    // });

    // requestTask.onError((error) => {
    //   console.error("请求错误:", error);
    // });
    // 流式监听
    const listener = (data) => {
      //const data = JSON.parse(parsedData); // 解析接收到的数据
      console.log("解析接收到的数据:", data);
      switch (data.type) {
        case "thought":
          // 处理工作流开始事件
          console.log("thought:", data);
          break;
        case "token_stat":
          // 处理工作流开始事件
          console.log("token_stat:", data);
          break;
        case "reply":
          // 处理工作流开始事件
          console.log("reply:", data);
          dataContent = dataContent + data.payload.content;
          console.log("dataContent:", dataContent);
          success && success(dataContent)
          break;
        case "node_started":
          // 处理节点开始事件
          console.log("节点已开始:", data);
          break;
        case "node_finished":
          // 处理节点完成事件
          console.log("节点已完成:", data);
          break;
        case "workflow_finished":
          // 处理工作流完成事件
          console.log("工作流已完成:", data);
          break;
        case "message":
          // 处理消息事件
          if (data.answer) {
            uni.hideLoading();
            // 检查list是否为空
            // 更新最新的元素
            const lastItem = list.value[list.value.length - 1];
            lastItem.returnSourceAnswer += data.answer; // 将新消息追加到最后一个元素的message中
          }
          break;
        case "message_end":
          // 处理消息结束事件
          console.log("消息结束:", data);
          loading.value = false;
          conversationId.value = data.conversation_id;
          // 更新历史记录中最新记录的 conversationId
          let history = uni.getStorageSync("searchHistory");
          if (history.length > 0) {
            history[0].conversationId = conversationId.value;
            uni.setStorageSync("searchHistory", history); // 更新存储
          }
          break;
        case "tts_message":
          // 处理文本转语音消息
          console.log("文本转语音消息:", data);
          break;
        case "tts_message_end":
          // 处理文本转语音消息结束
          console.log("文本转语音消息结束:", data);
          break;
        default:
          console.log("未知事件:", data);
      }
    };

    const arrayBufferToString = (arr) => {
      if (typeof arr === "string") {
        return arr;
      }
      var dataview = new DataView(arr);
      var ints = new Uint8Array(arr.byteLength);
      for (var i = 0; i < ints.length; i++) {
        ints[i] = dataview.getUint8(i);
      }
      var str = "",
        _arr = ints;
      for (var i = 0; i < _arr.length; i++) {
        if (_arr[i]) {
          var one = _arr[i].toString(2),
            v = one.match(/^1+?(?=0)/);
          if (v && one.length == 8) {
            var bytesLength = v[0].length;
            var store = _arr[i].toString(2).slice(7 - bytesLength);
            for (var st = 1; st < bytesLength; st++) {
              if (_arr[st + i]) {
                store += _arr[st + i].toString(2).slice(2);
              }
            }
            str += String.fromCharCode(parseInt(store, 2));
            i += bytesLength - 1;
          } else {
            str += String.fromCharCode(_arr[i]);
          }
        }
      }
      return str;
    };

    return {
      abort: () => {
        console.log("直接中断:");
        // 移除监听 需传入与监听时同一个的函数对象
        requestTask.offChunkReceived(listener)
        requestTask.abort()
      }
    }
  } catch (err) {
    console.error('[sse请求异常]', err)
    error(err)
    requestTask.abort()
  }
}